a0c37a5161a0c1a6dd4c4b5886025a9b12524867,nakadi-java-client/src/main/java/nakadi/OkHttpResource.java,OkHttpResource,requestThrowing,#String#String#ResourceOptions#Class#,116
Before Change
public <Res> Res requestThrowing(String method, String url, ResourceOptions options,
Class<Res> res) throws NakadiException {
if (null == retryPolicy) {
Response response = requestThrowingInner(method, url, options);
return marshalResponse(response, res);
} else {
Observable<Response> observable = Observable.defer(
() -> Observable.just(requestThrowingInner(method, url, options))
).compose(buildRetry(retryPolicy));
Response response = observable.toBlocking().first();
return marshalResponse(response, res);
After Change
public <Res> Res requestThrowing(String method, String url, ResourceOptions options,
Class<Res> res) throws NakadiException {
Observable<Response> observable =
Observable.defer(() -> Observable.just(requestThrowingInner(method, url, options)));
Response response = maybeComposeRetryPolicy(observable).toBlocking().first();
return marshalResponse(response, res);
}